package com.cn.client;

import com.cn.common.MessageQueue;

public interface OffsetStore {

    /**
     * 修改本地偏移量缓存
     *
     * @param messageQueue
     * @param offset
     */
    void updateOffset(MessageQueue messageQueue, Long offset);

    public void persit(MessageQueue messageQueue);

    public void persitAll();

    long readOffset(MessageQueue messageQueue);

    void remove(MessageQueue mq);

}
